package scoreAnalyze;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.mapreduce.Partitioner;
import org.apache.hadoop.io.Text;
public class DistributedPartitioner extends Partitioner<Text, IntWritable> {
    public int getPartition(Text key, IntWritable value, int numPartition){
        if(key.toString().equals("math"))
            return 0;
        if(key.toString().equals("english"))
            return 1;
        return 2;
    }

}
